package com.zhou.common.base.mq.mq.local;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;

@Data
@ConfigurationProperties(prefix = "rocketmq")
public class RocketMqProperties {

    private String nameServer;

    private Producer producer;

    private Consumer consumer;


    @Data
    public static class Producer {
        private String group;
        private Integer sendMessagetimeout;
        private Integer compressMessageBodyThreshold;
        private Integer maxMessageSize;
        private Integer retryTimesWhenSendFailed;
        private Integer retryTimesWhenSendAsyncFailed;
    }

    @Data
    public static class Consumer {

        private String group;
        private String commonTopic;

    }
}
